Bulkhead

JS/TS-friendly facade over com.sorinirmies.arrow.resiliencekit.Bulkhead.

import { Bulkhead } from "arrow-resilience-kit";

const bh = await Bulkhead.create({ maxConcurrentCalls: 10, maxWaitingCalls: 20 });
const result = await bh.execute(() => dbPool.query());

Types

Companion

object Companion

Functions

activeCalls

fun activeCalls(): Promise<Int>

Number of calls currently holding a permit.

execute

fun <T> execute(block: () -> Promise<T>): Promise<T>

Executes block, waiting for a permit. Rejects if the bulkhead is full (or times out waiting).

executeOrFallback

fun <T> executeOrFallback(fallback: () -> Promise<T>, block: () -> Promise<T>): Promise<T>

Executes block, falling back to fallback if the bulkhead is full.

resetStatistics

fun resetStatistics(): Promise<Unit>

Resets all statistics counters.

statistics

fun statistics(): Promise<BulkheadStatistics>

Current statistics snapshot.

tryExecute

fun <T> tryExecute(block: () -> Promise<T>): Promise<T?>

Executes block only if a permit is immediately available, resolving null otherwise.